package com.inventive.jmscache.server;

import javax.jms.JMSException;
import javax.jms.Queue;
import javax.jms.QueueReceiver;

/**
 * @author Grant Little grant.little@inventivesoftware.com.au
 */
public class JmsCacheQueueReceiver extends JmsCacheMessageConsumer implements QueueReceiver {

    public JmsCacheQueueReceiver(JmsCacheSession session, JmsCacheDestination destination, AcknowledgeMode acknowledgeMode) {
        super(session, destination, acknowledgeMode);
    }

    public JmsCacheQueueReceiver(JmsCacheSession session, JmsCacheDestination destination, String messageSelector, AcknowledgeMode acknowledgeMode, boolean noLocal) {
        super(session, destination, messageSelector, acknowledgeMode, noLocal);
    }

    public Queue getQueue() throws JMSException {
        return (Queue)destination;
    }
}
